package com.dtwave.cfstreaming.process.function;

import com.alibaba.fastjson.JSONObject;
import com.dtwave.utils.JsonUtils;
import org.apache.flink.api.common.functions.RichFilterFunction;

public class ProcessDataFilter extends RichFilterFunction<JSONObject> {
    @Override
    public boolean filter(JSONObject jsonObject) throws Exception {
        String tableName = JsonUtils.getString(jsonObject,true,"tableName");
        if("需要的表名".equals(tableName)){
            return true;
        }
        return false;
    }
}
